97645a29a6f95295c275117fabfac3b974284fd8,spring-cloud-vault-config/src/main/java/org/springframework/cloud/vault/config/LeasingVaultPropertySource.java,LeasingVaultPropertySource,doRevokeLease,#Lease#,212
Before Change
*/
private void doRevokeLease(final Lease lease) {
VaultResponseEntity<Map<String, Object>> entity = getSource().getVaultOperations()
.doWithVault(
new VaultOperations.SessionCallback<VaultResponseEntity<Map<String, Object>>>() {
@Override
public VaultResponseEntity<Map<String, Object>> doWithVault(
VaultOperations.VaultSession session) {
return session.putForEntity(String.format("sys/revoke/%s",
lease.getLeaseId()), null, Map.class);
}
});
if (entity.isSuccessful()) {
return;
}
throw new VaultException(
String.format("Cannot revoke lease: %s", buildExceptionMessage(entity)));
}
private static String buildExceptionMessage(VaultResponseEntity<?> response) {
After Change
private void doRevokeLease(final Lease lease) {
try {
getSource().getVaultOperations().doWithSession(
new RestOperationsCallback<ResponseEntity<Map<String, Object>>>() {
@Override
@SuppressWarnings("unchecked")
public ResponseEntity<Map<String, Object>> doWithRestOperations(
RestOperations restOperations) {
return (ResponseEntity) restOperations.exchange(
"/sys/revoke/{leaseId}", HttpMethod.PUT, null,
Map.class, lease.getLeaseId());
}
});
}
catch (HttpStatusCodeException e) {
throw new VaultException(String.format("Cannot revoke lease: %s",